//package com.sskj.mqtt.mica;
//
//import lombok.extern.slf4j.Slf4j;
//import net.dreamlu.iot.mqtt.codec.MqttQoS;
//import net.dreamlu.iot.mqtt.spring.client.MqttClientSubscribe;
//import org.springframework.stereotype.Service;
//
//import java.nio.charset.StandardCharsets;
//
//@Slf4j
//@Service
//public class MqttClientSubscribeListener {
//
//    @MqttClientSubscribe(value = "/test", qos = MqttQoS.EXACTLY_ONCE)
//    public void subQos2(String topic, byte[] payload) {
//        String message = new String(payload, StandardCharsets.UTF_8);
//        log.info("topic:{} payload:{}", topic, message);
//    }
//}
